package com.finance.cooperate.data.builder;

import com.finance.cooperate.common.pojo.RestResult;
import com.finance.cooperate.data.base.AbstractProcess;
import com.finance.cooperate.data.base.Builder;
import com.finance.cooperate.data.base.Reader;
import com.finance.cooperate.data.thread.ReaderQueue;
import lombok.extern.slf4j.Slf4j;

import java.util.Map;

/**
 * @ClassName FeatureProcess
 * @Description 特征处理器
 * @Author shen
 * @Date 2023/8/10 18:09
 * @Modify ...
 */
@Slf4j
public class FeatureProcess extends AbstractProcess {
    @Override
    public RestResult run(String userId, Builder<Reader> builder) {

        Map<String, String> map = super.init(userId, builder);


        // 特征输出
        ReaderQueue.getInstance().put(map);

        return RestResult.ok();
    }
}
